//package com.xiguaji.tiktok.task.market.service;
//
//import com.gugee.tiktok.common.model.dal.blogger.BloggerLogRepository;
//import com.gugee.tiktok.common.model.mysql.BloggerLog;
//import com.xiguaji.tiktok.task.common.job.TaskParam;
//import com.xiguaji.tiktok.task.common.producer.AbstractProducerHandler;
//import com.xxl.job.core.log.XxlJobLogger;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//import java.text.ParseException;
//import java.text.SimpleDateFormat;
//import java.time.LocalDateTime;
//import java.time.format.DateTimeFormatter;
//import java.util.List;
//@Slf4j
//@Component
//public class MarkerService extends AbstractProducerHandler<MarkerService> {
//    @Autowired
//    BloggerLogRepository bloggerLogRepository;
//    public int updateMarkerHande(int bloggerLogType, String who,TaskParam taskParam){
//        long start=System.currentTimeMillis();
//        //获取位置
//        BloggerLog bloggerLog=getBloggerLog(bloggerLogType,who);
//        long page=bloggerLog.getCurrentBloggerId();
//        if(1==bloggerLog.getCurrentBloggerId()){
//            String timeStr2= LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
//            bloggerLog.setFirstPageStartTime(timeStr2);
//
//        }
//        int code=fetchBloggerMarketEventListener.handle((int)page,who,taskParam);
//        if(code==0){
//            page++;
//        }
//
//
//        bloggerLog.setCurrentBloggerId(page);
//        if(code==30181) {
//            page=1;
//            XxlJobLogger.log("进入下一轮循环，下一次第一页开始");
//            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//            try {
//                long mills = System.currentTimeMillis() - sdf.parse(bloggerLog.getFirstPageStartTime()).getTime();
//                bloggerLog.setMoreInfo("起始页=" + taskParam.getStartPage() + ",需轮询总页数=" + bloggerLog.getCurrentBloggerId() + ",上一轮花费(分钟)=" + mills / 1000 / 60 + ",上一轮开始时间=" + bloggerLog.getFirstPageStartTime());
//                log.warn("页码={} ，无数据,下一次将从{}页开始", bloggerLog.getCurrentBloggerId(), page);
//                XxlJobLogger.log("页码={} ，无数据,下一次将从{}页开始", bloggerLog.getCurrentBloggerId(), page);
//            } catch (ParseException e) {
//                e.printStackTrace();
//            }
//        }
//        bloggerLogRepository.save(bloggerLog);
//
//       XxlJobLogger.log("  page={}, times={}秒", bloggerLog.getCurrentBloggerId() ,(System.currentTimeMillis()-start)/1000);
//        return code;
//    }
//
//    @Override
//    public List<MarkerService> findMessageObject(BloggerLog bloggerLog, TaskParam taskParam) {
//        return null;
//    }
//
//    @Override
//    public void sendMsg(List<MarkerService> messages, String topic) {
//
//    }
//}
